package com.hm.hall.commons.service.amqp;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AmqpHello {
    @Autowired
    private Receiver receiver;
    @Autowired
    private Sender sender;

    @Async("taskThreadExecutor")
    public void sendHello(int i) {
        sender.send(i);
    }

    /*@Async
    public void receiverHello(){
        receiver.process("dd");
    }*/
}
